package com.sunl.mall.ali.mq.producer;

import com.sunl.mall.ali.mq.model.RocketMqMessageWrapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Properties;

/**
 * 做一些消息体大小等信息的检查操作
 */
public class AbstractRocketMqProducer {
    private final static Logger log = LoggerFactory.getLogger(AbstractRocketMqProducer.class);
    private Properties properties;

    public void init(Properties properties) {
        this.properties = properties;
    }

    protected <T> boolean checkSendMsgBody(RocketMqMessageWrapper<T> message) {
        return true;
    }
}
